package org.apache.flink.runtime.resourceconsumer;

import org.apache.flink.util.ERException;

/** {@code JobCancellationFailedException} is thrown if the cancellation of a job failed. */
/**
 * @类名: ConsumeCancellationFailedException
 * @说明: 消费取消失败异常
 *
 * @author   leehom
 * @Date	 2024年2月19日 上午10:32:14
 * 修改记录：
 *
 * @see 	 
 */
public class ConsumeCancellationFailedException extends ERException {

    private static final long serialVersionUID = -5351974867056033752L;

    public ConsumeCancellationFailedException(String message) {
        super(message);
    }

    public ConsumeCancellationFailedException(String message, Throwable cause) {
        super(message, cause);
    }
}
